package com.pz.gulimall.order.service.impl;

import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.pz.gulimall.order.dao.MqMessageDao;
import com.pz.gulimall.order.entity.MqMessageEntity;
import com.pz.gulimall.order.service.MqMessageService;
import org.springframework.stereotype.Service;

import java.util.Date;

@Service("mqMessageService")
public class MqMessageServiceImpl extends ServiceImpl<MqMessageDao, MqMessageEntity> implements MqMessageService {
    @Override
    public void updateMsgStatus(String msgId, Integer newStatus) {
        this.update(new UpdateWrapper<MqMessageEntity>().set("message_status", newStatus).set("update_time", new Date()).eq("message_id", msgId));
    }
}
